package com.hjs.mr.merge_and_sort;

import org.apache.hadoop.io.NullWritable;
import org.apache.hadoop.mapreduce.Partitioner;

/**
 * 自定义的分区器，主要是为了将三个文件读取的数据经过处理之后传入到一个分区器进行输出，因为一开始在创建SortBean的时候就是先将sort字段赋值都是0的，所以肯定是进入一个分区
 */
public class SortPartitioner extends Partitioner<SortBean, NullWritable> {
    @Override
    public int getPartition(SortBean sortBean, NullWritable nullWritable, int i) {
        return sortBean.getSort();
    }
}
